package com.jxstjh.conch.stream.constants;

public class ConchStreamConstant {

    /**
     * Kafka 配置信息
     * TODO 配置具体的kafka broker ip:port
     */
    public static final String GROUP_ID = "conch_log_group";
    public static final String TOPIC_NAME = "conch_lg";
    public static final String BROKER = "ip:port";

    /**
     * redis 配置
     * TODO 使用前配置redis ip:port
     */
    public static final String REDIS_IP = "ip";
    public static final String REDIS_PORT = "port";
    public static final String REDIS_PASSWORD = "JXst2022@8jhYF";


    /**
     * flink流程常量
     */
    public static final String SOURCE_NAME = "conch_kafka_source";
    public static final String FUNCTION_NAME = "conch_transfer";
    public static final String SINK_NAME = "conch_sink";
    public static final String JOB_NAME = "ConchStreamApplication";
}